package ThreadPoolRunnable;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolTest {
    public static void main(String[] args) {
        // 创建一个大小为3的线程池
        ExecutorService executor = Executors.newFixedThreadPool(3);

        // 提交十个任务交给线程池执行
        for (int i = 1; i <= 10; i++) {
            int taskNumber = i; // 保存任务编号
            executor.execute(new MyRunnable(taskNumber));
        }

        // 关闭线程池，不再接受新任务，已提交的任务将完成后关闭
        executor.shutdown();

        // 等待所有任务完成
        while (!executor.isTerminated()) {
            // 这里可以添加一些等待逻辑，例如打印信息或休眠
        }

        System.out.println("Finished all threads");
    }
}